//package cn.uexpo.lhz.common;
//
//import org.springframework.amqp.core.Binding;
//import org.springframework.amqp.core.BindingBuilder;
//import org.springframework.amqp.core.Queue;
//import org.springframework.amqp.core.TopicExchange;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.stereotype.Component;
//
//@Component
//@Configuration
//public class SendConfig {
//
//    /**
//     * 定义队列和交换机
//     */
//
//    //队列邮件
//    public static final String TOPIC_QUEUE_1 = "topic.queue.email";
//
//    //队列短信
//    public static final String TOPIC_QUEUE_2 = "topic.queue.sms";
//
//    //队列钉钉
//    public static final String TOPIC_QUEUE_3 = "topic.queue.dingDing";
//
//    //队列钉钉
//    public static final String TOPIC_QUEUE_4 = "topic.queue.staffMsg";
//
//
//
//
//    //交换机
//    public static final String TOPIC_EXCHANGE = "topic.exchange";
//
//
//    /**
//     * 定义路由键
//     */
//
//    //根据key获取
//    public static final String TOPIC_ROUTING_KEY_1 = "topic.message.rabbit";
//
//    // * 代表获取一个
//    public static final String TOPIC_ROUTING_KEY_2 = "topic.message.*";
//
//    // # 代表获取全部
//    public static final String TOPIC_ROUTING_KEY_3 = "topic.#";
//
//    //测试
//    public static final String TOPIC_ROUTING_KEY_4 = "topic.message.staffMsg";
//
//    /**
//     * 创建队列
//     * @return
//     */
//    @Bean
//    public Queue queue1() {
//        //队列1
//        return new Queue(TOPIC_QUEUE_1);
//    }
//
//
//    @Bean
//    public Queue queue2() {
//        //队列2
//        return new Queue(TOPIC_QUEUE_2);
//    }
//
//    @Bean
//    public Queue queue3() {
//        //队列3
//        return new Queue(TOPIC_QUEUE_3);
//    }
//
//
//    @Bean
//    public Queue queue4() {
//        //队列3
//        return new Queue(TOPIC_QUEUE_4);
//    }
//
//    /**
//     * 创建交换机
//     * @return
//     */
//    @Bean
//    public TopicExchange topicExchange() {
//        return new TopicExchange(TOPIC_EXCHANGE);
//    }
//
//
//    /**
//     * 交换机 路由绑定
//     * @return
//     */
//
//    @Bean
//    public Binding binding1() {
//        //根据key获取
//        return BindingBuilder.bind(queue1()).to(topicExchange()).with(TOPIC_ROUTING_KEY_1);
//    }
//
//    @Bean
//    public Binding binding2() {
//        // * 代表获取一个
//        return BindingBuilder.bind(queue2()).to(topicExchange()).with(TOPIC_ROUTING_KEY_2);
//    }
//
//    @Bean
//    public Binding binding3() {
//        // # 代表获取全部
//        return BindingBuilder.bind(queue3()).to(topicExchange()).with(TOPIC_ROUTING_KEY_3);
//    }
//
//
//    @Bean
//    public Binding binding4() {
//        // # 代表获取全部
//        return BindingBuilder.bind(queue4()).to(topicExchange()).with(TOPIC_ROUTING_KEY_4);
//    }
//
//}
